package com.distribute.framework.plugin;

public abstract class BaseMQ {
	
	/**
	 * 发送文本消息
	 * @param destination
	 * @param message
	 */
	public abstract void sendTextMessage(String flag,String destinationName, final String message,Boolean isP2P);
	
	/**
	 * 动态创建监听
	 * @param destinationName
	 * @param messageListener
	 */
	public abstract void addMessageListener(String flag,String[] destinationNames,final Notify.Listener notifyListener,Boolean isP2P);

}